let api = 'http://rpc-serveruat:8121/api/'
if(process.env.ServerApp === 'prod'){
  api = 'http://rpc-serverprod:8137/api/'
}
import axios from 'axios'

export class WsStartGateway {


  postUpdateNotice(wx_user: string, data?: any){
    if(!wx_user) return
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updateNotice', data: {wx_user}})).then(() => {}).done();
    // }
    
    axios.post(api + 'updateNotice', {wx_user: wx_user})

    // this.server.to(wx_user).emit('updateNotice', data);
  }

  postUpdatePlatformInfo(wx_user: string, data?: any){
    if(!wx_user) return
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updatePlatformInfo', data: {wx_user}})).then(() => {}).done();
    // }

    axios.post(api + 'updatePlatformInfo', {wx_user: wx_user})

    // this.server.to(wx_user).emit('updatePlatformInfo', data);
  }

  /**
   * 更新我的数据
   * @param wx_user 
   */
  postUpdateMyData(wx_user: string, video_id: any){
    if(!wx_user || !video_id) return
    // this.server.to(wx_user).emit('updateMyData', video_id);
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updateMyData', data: {wx_user, video_id: video_id}})).then(() => {}).done();
    // }

    axios.post(api + 'updateMyData', {wx_user, video_id: video_id})

  }

  postUpdateProfitRefund(wx_user: any, video_id: any){
    if(!wx_user || !video_id) return
    // this.server.to(wx_user).emit('updateMyData', video_id);
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updateMyData', data: {wx_user, video_id: video_id}})).then(() => {}).done();
    // }

    axios.post(api + 'updateProfitRefund', {wx_user, video_id: video_id})
  }


  /**
   * 通知用户更新
   * @param video_id 
   */
  postUpdateVideo(video_id: number){
    if(!video_id) return
    // this.server.to(`video_id_${video_id}`).emit('updateVideo', video_id)
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updateVideo', data: {video_id}})).then(() => {}).done();
    // }

    axios.post(api + 'updateVideo', {video_id})

  }


  /**
   * 更新关注红点
   * @param wx_user 
   * @param data 
   * @returns 
   */
  postUpdateConcern(wx_user: string){
    // //生成回调类
    // var success = function (result) {
    //   console.log("remote server endpoint:",             result.request.RemoteEndpoint.toString());   //本次调用对应的服务端地址，类型为['tars-utils'].Endpoint
    //   console.log("result.response.costtime:",           result.response.costtime);                   //本地调用的耗时，单位为毫秒
    //   console.log("result.response.return: ",            result.response.return);                     //函数的返回值（在tars文件中定义）
    //   console.log("result.response.arguments.sValue1:",  result.response.arguments.data);          //函数的out参数（在tars文件中定义）
    // }
    // var error = function (result) {
    //   console.log("result.response.error.code: ",        result.response.error.code);                 //本次调用失败的错误代码
    //   console.log("result.response.error.message: ",     result.response.error.message);              //本次调用失败的错误描述
    // }

    // //调用接口
    // if(prx?.postMessage){
    //   prx.postMessage(JSON.stringify({action:'updateConcern', data:{ wx_user: wx_user }})).then(success, error).done();
    // }

    axios.post(api + 'updateConcern', {wx_user: wx_user})

  }

}
